//package com.taldh.kafka.controller;
//
//import com.taldh.kafka.bean.TestDto;
//import org.springframework.web.bind.annotation.PostMapping;
//import org.springframework.web.bind.annotation.RequestBody;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import javax.annotation.Resource;
//import java.io.Serializable;
//
//@RestController
//@RequestMapping("test")
//public class TestController {
//
////    @Resource
////    ProducerService producerService;
//
////    @PostMapping("sendJson")
////    public void sendJson(@RequestBody SendJsonObject jsonObject) {
////        producerService.sendJson(jsonObject.getTopic(), JSONObject.toJSONString(jsonObject.getLoanSuccessPojo()));
////    }
//
//
//    @PostMapping("getMsg")
//    public void getMsg(@RequestBody TestDto msg) {
//        System.out.println(msg);
//    }
//
//}
